package com.dhcc.activemq.producer;

import javax.jms.Queue;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 
* <p>标题: P2PProducer.java</p>
* <p>业务描述:点对点发送</p>
* <p>公司:东华软件股份公司</p>
* <p>版权:dhcc2013</p>
* @author 胡凯
* @date 2019年7月29日
* @version V1.0
 */
//@Component
@RestController
@RequestMapping("/queue")
public class P2PProducer {
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    //把队列注入进来 
    @Autowired  //此注解默认是以类型找  在配置文件中 已经注入的  @Bean 
    private Queue queue;

    
    //每隔5s时间向队列发送消息
    //@Scheduled(fixedDelay=5000)  //每间隔2s向队列发送消息
    @RequestMapping("send")
    public void sendByQueue(String name) {
//        String msgString = System.currentTimeMillis()+" ";
        jmsMessagingTemplate.convertAndSend(queue,name);
        System.out.println("点对点通讯，name="+name);
    }
    

}